package com.example.concurrentprogramming8016.piped;

import java.io.IOException;
import java.io.PipedReader;
import java.io.PipedWriter;
import java.util.concurrent.atomic.AtomicInteger;
import java.util.concurrent.atomic.AtomicStampedReference;
import java.util.concurrent.atomic.LongAdder;

/**
 * @author liyanhao
 * @Date 2023-02-08 0:33
 */
public class PipedDemo {
    public static void main(String[] args) throws IOException {
        PipedWriter out = new PipedWriter();
        PipedReader in = new PipedReader();
        //将输入流和输出流进行链接，否则在使用的时候会抛出IOException
        out.connect(in);
    }
}
